// 处理数据库请求的文件
// 导入MySQL模块 + 数据库的配置文件
const mysql = require("mysql")
const config = require("./db.config")

// 创建连接
function connct(){
    const {host , user , password , database} = config
    return mysql.createConnection({
        host,// 简写形式 完整写法 host : host
        user,
        password,
        database,
    })
}

// 执行SQL语句
function querySql(sql){// 需要接收参数 接收的内容是需要执行的SQL语句
    // 连接数据库
    const conn = connct()
    return new Promise((resolve,reject)=>{
        try{
            conn.query(sql,(err,res)=>{
                if(err){
                    reject(err)
                }else{
                    resolve(res)
                }
            })
        }catch(e){
            reject(e)
        }finally{
            // 执行完毕关闭连接
            conn.end()
        }
    })
}

// 导出
module.exports = {
    querySql
}